// Copyright (C) 2022 即时通讯网(52im.net) & Jack Jiang.
// The RainbowChat Project. All rights reserved.
// 
// 【本产品为著作权产品，合法授权后请放心使用，禁止外传！】
// 【本次授权给：<广西木子科技有限公司>，授权编号：<NT220402151538>，代码指纹：<A.648883738.885>，技术对接人微信：<ID: Lingmuziyi>】
// 【授权寄送：<收件：李先生、地址：南宁市科园西十路11号国电智能大厦1101F、电话：17736659550、邮箱：yingshashou@vip.qq.com>】
// 
// 【本系列产品在国家版权局的著作权登记信息如下】：
// 1）国家版权局登记名(简称)和权证号：RainbowChat    （证书号：软著登字第1220494号、登记号：2016SR041877）
// 2）国家版权局登记名(简称)和权证号：RainbowChat-Web（证书号：软著登字第3743440号、登记号：2019SR0322683）
// 3）国家版权局登记名(简称)和权证号：RainbowAV      （证书号：软著登字第2262004号、登记号：2017SR676720）
// 4）国家版权局登记名(简称)和权证号：MobileIMSDK-Web（证书号：软著登字第2262073号、登记号：2017SR676789）
// 5）国家版权局登记名(简称)和权证号：MobileIMSDK    （证书号：软著登字第1220581号、登记号：2016SR041964）
// * 著作权所有人：江顺/苏州网际时代信息科技有限公司
// 
// 【违法或违规使用投诉和举报方式】：
// 联系邮件：jack.jiang@52im.net
// 联系微信：hellojackjiang
// 联系QQ号：413980957
// 授权说明：http://www.52im.net/thread-1115-1-1.html
// 官方社区：http://www.52im.net
package com.x52im.rainbowchat.http.logic;

import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Vector;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.dysmsapi20170525.models.SendSmsResponse;
import com.eva.epc.common.file.FileHelper;
import com.eva.epc.common.util.CommonUtils;
import com.eva.epc.common.util.RestHashMap;
import com.eva.framework.Processor;
import com.eva.framework.dbpool.DBDepend;
import com.eva.framework.dbpool.DBShell;
import com.eva.framework.dto.SysActionConst;
import com.eva.framework.utils.EndsExceptionFactory;
import com.eva.framework.utils.LoggerFactory;
import com.x52im.rainbowchat.BaseConf;
import com.x52im.rainbowchat.MyControllerJSONP;
import com.x52im.rainbowchat.cache.GroupsInfoCacheProvider;
import com.x52im.rainbowchat.cache.GroupsMembersCacheProvider;
import com.x52im.rainbowchat.cache.UsersInfoCacheProvider;
import com.x52im.rainbowchat.http.logic.dto.OfflineMsgDTO;
import com.x52im.rainbowchat.http.logic.dto.RosterElementEntity;
import com.x52im.rainbowchat.http.logic.dto.UserRegisterDTO;
import com.x52im.rainbowchat.http.logic.logic.*;
import com.x52im.rainbowchat.http.util.ip.IPSeeker;
import com.x52im.rainbowchat.http.util.ip._Utils;
import com.x52im.rainbowchat.im.ChatServerEventListener;
import com.x52im.rainbowchat.im.dto.CMDBody4AddFriendRequest;
import com.x52im.rainbowchat.im.dto.CMDBody4ProcessFriendRequest;
import com.x52im.rainbowchat.im.impl.ChatLogicManager;
import com.x52im.rainbowchat.im.impl.ChatLogicManager4Group;
import com.x52im.rainbowchat.im.util.MessageHelper;

/**
 * 基本Http业务接口处理器实现类。
 *
 * @author Tony ma, Jack Jiang
 */
public class LogicProcessor2 implements SysActionConst, Processor {
    public static DBShell db = new DBShell();

    /**
     * 处理器的核心实现方法.<br>
     * 可据job_dispatch_id找到对应的JobDispatcher，JobDispatcher又能据
     * action_id进行对应动作的处理，以完成本次操作请求.
     *
     * @param job_dispatch_id 作业调度ID
     * @param action_id       动作ID
     * @param Object          newData 客端发送过来的本次修改新数据(可能为空，理论上与oldData不会同时空）
     * @param Object          oldData 客端发送过来的本次修改前的老数据(可能为空，理论上与newData不会同时空）
     * @param UserRoot        user 包含该请求用户完整个人信息封装对象（该对象来自于成功登陆后存放于session中的值）
     * @return 任意类型返回值
     * @throws Exception
     */
    @Override
    public Object process(int job_dispatch_id, int action_id, Object _newData, Object _oldData, User user) throws Exception {
        Object ret = null;
        String newDataJSON = (String) _newData;

        switch (job_dispatch_id) {
            // 处理用户注册业务逻辑
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_REGISTER:// ok
                ret = new RegisterJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;
            // 好友管理逻辑
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_ROSTER:// ok
                ret = new RosterMgrJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;
            // 社交关系管理逻辑
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_SNS:// ok
                ret = new SNSJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;
            // 消息管理逻辑
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_MESSAGES:
                ret = new MessagesJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;
            // 删除好友
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_DELETE$FRIEND:// ok
                ret = new DeleteFriendJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;
            // 处理个人相册、个人介绍语音留言等个人详细信息资源的管理
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_MGR$PROFILE:
                ret = new MgrProfileJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;

            // 处理通用数据查询接口逻辑的管理
            // 说明：除了因历史原因已散落在其它区的查询代码，新增加的查询接口都应该放到本管理器里
            case com.x52im.rainbowchat.http.logic.dto.JobDispatchConst.LOGIC_COMMON_QUERY_MGR:
                ret = new CommonQueryJobDispatcher().dispatch(action_id, newDataJSON, _oldData, user);
                break;

            default:
                throw EndsExceptionFactory.INVALID_JOB_DISPATCHER_ID(job_dispatch_id);
        }
        return ret;
    }
}
